
#ifndef __M2M_SOCKET_H__
#define __M2M_SOCKET_H__

//MQTT TOPIC---------
//#define   WX_TOPIC
//#define   ORKAN_TOPIC
//#define   ORKAN_TOPIC_XF_V1_1
//#define   JIABANG_TOPIC
//#define   DIJIA_TOPIC
//#define   ZEFENG_TOPIC
//#define   ZHONGQING_TOPIC
#define   LJN_TOPIC
//#define   JINGGE_TOPIC
//微信ID---------
//#define    ID_JIABANG
//#define    ID_ZEFENG
//#define    ID_DIJIA
//#define    ID_GEEK
//#define    ID_JINGGE
#define    ID_LJN
//#define    ID_WX


#define  _sys_debug_

//#define _BANTRATE9600_


#define MQTT_SOCKET_SEND_BUF_SIZE   (1024)
#define MQTT_SOCKET_RECV_BUF_SIZE   (1024)

#pragma pack(1)

typedef struct __socket_para__
{
	uint8_t recv_buf[MQTT_SOCKET_RECV_BUF_SIZE];
	int fd;
	uint8_t connect_status;
}socket_para;

typedef struct __topic_para__
{	
	uint16_t msg_id;
	char name[0];
}topic_para;

extern void mqtt_tcp_connect(char *addr, int port);
extern void app_mqtt_init(mqtt_broker_handle_t *broker);
extern void mqtt_process_init_start(void);

#pragma pack()

#endif
